package com.paradogs.framework.core.queue;

import com.paradogs.framework.core.msg.ByteData;
import com.paradogs.framework.core.utils.MsgUtils;
import lombok.extern.slf4j.Slf4j;

import java.lang.reflect.InvocationTargetException;

/**
 * @author: yumi
 * @date: 2023/7/28  9:27
 * @Description: 消息处理线程
 */
@Slf4j
public class MsgDefaultConsumer extends AbstractMsgConsumer {

    /**
     * 消息处理
     * @param msg
     */
    @Override
    public void handle(ByteData msg) throws InvocationTargetException, IllegalAccessException {
        MsgUtils.adapterHandle(msg);
    }

}
